package com.example.consumer;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.cloud.stream.function.StreamBridge;

@SpringBootTest
public class ConsumerApplicationTest {

    @Autowired
    private StreamBridge streamBridge;

    @Test
    public void sendMessage() {
        streamBridge.send("producer-in-0", "hello");
    }

}
